package io.mft.commons.config.mq;

import io.mft.commons.function.response.kv.KVMap;
import lombok.Getter;
import lombok.Setter;

@Setter
@Getter
public class MqConsumer {
	private String id;
	private String datasourceId;
	private String queueId;
	// 是否重试
	private boolean retry = true;
	// 重试次数
	private int retryNum = 100;
	private int concurrent = 1;
	private int maxConcurrent = 2;
	private String note;
	private KVMap configs;
	private MqHandlerMode handlerMode;
	private String handler;
}
